const { dbCmd, userCollection } = require("../../common/constants");
const { USER_IDENTIFIER } = require("../../common/constants");
const {
  batchFindObjctValue,
  getType,
  isMatchUserApp,
} = require("../../common/utils");

/**
 * 查询满足条件的用户
 * @param {Object} params
 * @param {Object} params.userQuery 用户唯一标识组成的查询条件
 * @param {Object} params.authorizedApp 用户允许登录的应用
 * @returns userMatched 满足条件的用户列表
 */
async function findUser(params = {}) {
  const { userQuery, authorizedApp = [] } = params;
  const condition = getUserQueryCondition(userQuery);
  if (condition.length === 0) {
    throw new Error("Invalid user query");
  }
  const authorizedAppType = getType(authorizedApp);
  if (authorizedAppType !== "string" && authorizedAppType !== "array") {
    throw new Error("Invalid authorized app");
  }

  let finalQuery;

  if (condition.length === 1) {
    finalQuery = condition[0];
  } else {
    finalQuery = dbCmd.or(condition);
  }
  const userQueryRes = await userCollection.where(finalQuery).get();
  return {
    total: userQueryRes.data.length,
    userMatched: userQueryRes.data.filter((item) => {
      return isMatchUserApp(item.dcloud_appid, authorizedApp);
    }),
  };
}

function getUserIdentifier(userRecord = {}) {
  const keys = Object.keys(USER_IDENTIFIER);
  return batchFindObjctValue(userRecord, keys);
}

function getUserQueryCondition(userRecord = {}) {
  const userIdentifier = getUserIdentifier(userRecord);
  const condition = [];
  for (const key in userIdentifier) {
    const value = userIdentifier[key];
    if (!value) {
      // 过滤所有value为假值的条件，在查询用户时没有意义
      continue;
    }
    const queryItem = {
      [key]: value,
    };
    // 为兼容用户老数据用户名及邮箱需要同时查小写及原始大小写数据
    if (key === "mobile") {
      queryItem.mobile_confirmed = 1;
    } else if (key === "email") {
      queryItem.email_confirmed = 1;
      const email = userIdentifier.email;
      if (email.toLowerCase() !== email) {
        condition.push({
          email: email.toLowerCase(),
          email_confirmed: 1,
        });
      }
    } else if (key === "username") {
      const username = userIdentifier.username;
      if (username.toLowerCase() !== username) {
        condition.push({
          username: username.toLowerCase(),
        });
      }
    } else if (key === "identities") {
      queryItem.identities = dbCmd.elemMatch(value);
    }
    condition.push(queryItem);
  }
  return condition;
}

module.exports = {
  findUser,
  getUserIdentifier,
};
